package com.tdd.reactor;

import java.util.ArrayList;

/**
 * @author fanhb on 2022/11/18
 * <p>
 * desc xxxx
 */
public class MyEventProcessor {

    public void register(ReactorTest.MyEventListener<String> myEventListener) {

        ArrayList<String> list = new ArrayList<>();

        list.add("1");
        list.add("1");
        list.add("1");
        list.add("1");
        myEventListener.onDataChunk(list);
        myEventListener.processComplete();
    }

}
